package com.turato.table.processor;

import com.turato.table.service.MsgService;
import org.springframework.beans.factory.annotation.Autowired;

import java.util.List;

/**
 * @author tuhao
 * @date 2021/2/10 11:10 上午
 * @desc
 */
public class MsgProcessor {

    /**
     * 	通过spring容器将所有实现 MsgService 接口的类的实例注入进来
     */
    @Autowired
    private List<MsgService> msgServiceList;

    /**
     *  使用支持channelType的供应商发送消息
     * @param channelType 供应商类型
     * @param content 消息
     */
    public void send(String channelType, String content) {
        for (MsgService msgService : msgServiceList) {
            msgService.send(channelType, content);
        }
    }
}
